/*
package cn.simon.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

*/
/**
 * @功能描述： RabbitMq配置类-直连模式
 * @Auther: simon-yi'an
 *//*

@Configuration
public class RabbitMqDirectConfig {
    private static final String QUEUE_DIRECT01 = "queue_direct01";
    private static final String QUEUE_DIRECT02 = "queue_direct02";
    private static final String DIRECTEXCHANGE = "directExchange";
    private static final String ROUTINGKEY01 = "routingkey_red";
    private static final String ROUTINGKET02 = "routingkey_greed";
    @Bean
    public Queue queue_direct01(){
        return new Queue(QUEUE_DIRECT01);
    }
    @Bean
    public Queue queue_direct02(){
        return new Queue(QUEUE_DIRECT02);
    }
    @Bean
    public DirectExchange directExchange(){
        return new DirectExchange(DIRECTEXCHANGE);
    }
    @Bean
    public Binding bindred(){
        return BindingBuilder.bind(queue_direct01()).to(directExchange()).with(ROUTINGKEY01);
    }
    @Bean
    public Binding bindGreed(){
        return BindingBuilder.bind(queue_direct02()).to(directExchange()).with(ROUTINGKET02);
    }
}
*/
